// package com.yilong.springcloudalibabanacos.sys.config;
//
// import lombok.extern.slf4j.Slf4j;
// import org.apache.rocketmq.client.exception.MQClientException;
// import org.apache.rocketmq.client.producer.DefaultMQProducer;
// import org.springframework.beans.factory.annotation.Value;
// import org.springframework.context.annotation.Bean;
// import org.springframework.context.annotation.Configuration;
//
// /**
//  * @ProjectName: springcloud-alibaba-yilong
//  * @Package: com.yilong.springcloudalibabanacos.sys.config
//  * @ClassName: DefaultProducerConfig
//  * @Author: WYL
//  * @Description:
//  * @Date: 2021/8/29 20:16
//  * @Version: 1.0.0
//  */
//
// @Slf4j
// @Configuration
// public class DefaultProducerConfig {
//
//     @Value("${rocketmq.name-server}")
//     private String namesrvAddr;
//
//     @Value("${rocketmq.producer.group}")
//     private String producerGroup;
//
//     /**
//      * 创建普通消息发送者实例
//      *
//      * @return
//      * @throws MQClientException
//      */
//     @Bean
//     public DefaultMQProducer defaultProducer() throws MQClientException {
//         DefaultMQProducer producer = new DefaultMQProducer(producerGroup);
//         producer.setNamesrvAddr(namesrvAddr);
//         producer.setVipChannelEnabled(false);
//         producer.setRetryTimesWhenSendAsyncFailed(10);
//         producer.start();
//         log.info("default producer 创建成功, {}, {}", namesrvAddr, producerGroup);
//         return producer;
//     }
// }
